package client

import "time"

// Kafka Message
type KafkaMessage struct {
	// Message
	Messages Message `json:"message"`
	// 主题
	Topic string `json:"topic"`
	// Key hash分区
	Key string `json:"key"`
}

type Message struct {
	// 消息数据
	Data map[string]interface{} `json:"data"`
	// 消息时间
	Timestamp int `json:"timestamp"`
}

type MessageError struct {
	Error     error
	Topic     string
	Timestamp time.Time
	Partition int32
	Offset    int64
	Metadata  interface{}
}